const mysql = require("mysql");

function query(sql, params) {
    // 创建连接
    var connection = mysql.createConnection({
        host: "localhost",
        user: "root",
        password: "root",
        database: "zk2",
    });

    // 测试是不是连接成功了
    connection.connect();

    // 发送 SQL 语句，因为我们要使用 async/await 语法，所以这里就返回一个 promise
    return new Promise((resolve, reject) => {
        connection.query(sql, params, function (error, results, fields) {
            if (error) {
                reject(error);
            } else {
                resolve(results);
            }
        });

        // 关闭连接
        connection.end();
    });
}

module.exports = query;
